//package com.open.yujiakj.utils.redis;
//
//
//import lombok.extern.slf4j.Slf4j;
//import org.apache.commons.lang.math.NumberUtils;
//import org.apache.commons.lang3.StringUtils;
//import org.apache.commons.logging.Log;
//import org.apache.commons.logging.LogFactory;
//import redis.clients.jedis.HostAndPort;
//import redis.clients.jedis.JedisCluster;
//
//import javax.annotation.PostConstruct;
//import java.util.ArrayList;
//import java.util.HashSet;
//import java.util.List;
//import java.util.Set;
//
///**
// * 集群版redis工具类
// *
// *
// *
// */
//@Slf4j
//public class RedisClusterUtil {
//
//	private Log logger = LogFactory.getLog(this.getClass());
//
//	private static   JedisCluster jedisCluster ;
//
//
//
//	@PostConstruct
//	private void init() {
//		redisClusterAddress = env.getProperty("redis.cluster.address");
//		if (StringUtils.isEmpty(redisClusterAddress)) {
//			logger.info("没有配置redis集群(redis.cluster.address)[ip1:port1,ip2:port2]，不启动redis集群客户端");
//			return;
//		}
//		String[] address = redisClusterAddress.split(",");
//		Set<HostAndPort> nodes = new HashSet<HostAndPort>();
//		for (String node : address) {
//			if (StringUtils.isEmpty(node)) {
//				continue;
//			}
//			String[] hostAndPort = node.split(":");
//			if (hostAndPort.length != 2) {
//				continue;
//			}
//			HostAndPort hp = new HostAndPort(hostAndPort[0], NumberUtils.toInt(hostAndPort[1], 6379));
//			nodes.add(hp);
//		}
//		jedisCluster = new JedisCluster(nodes);
//	}
//
//
//}
